package org.bongo.open.cumulo.procengine.broker;

import org.bongo.open.cumulo.core.message.MessageUnit;

public interface ProcEnginePartitioner {
	public int getPartition(MessageUnit<?> message);
}
